package com.clstu.homeworks;

public class Homework02 {
    public static void main(String[] args) {
//        GetMoney getMoney = new GetMoney();
//        GetMoney getMoney1 = new GetMoney();
//        getMoney.setName("A");
//        getMoney1.setName("B");
//        getMoney.start();
//        getMoney1.start();
        T t = new T();
        Thread thread = new Thread(t);
        Thread thread1 = new Thread(t);
        thread.setName("AA");
        thread1.setName("BB");
        thread1.start();
        thread.start();

    }
}
class GetMoney extends Thread{//方式1 继承Thread

    private static int money = 10000;
    private static Object o = new Object();
    private int count=0;

    @Override
    public void run() {
        {//对象互斥锁，谁抢到谁执行，一次不会执行两个进程
                         //对象互斥锁是一个非公平锁，抢不到的可能永远抢不到
            while (true) {
                synchronized (o) {

                    if (money < 1000) {
                        System.out.println("余额已经不足了。。");
                        break;
                    }
                    System.out.println(Thread.currentThread().getName() + "线程取钱： 1000块 -------" + (++count) + "剩余余额：" + money);
                    money -= 1000;
                    try {
                        Thread.sleep(1000);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
            System.out.println(Thread.currentThread().getName() + "已经运行结束~~");
        }
    }
}

class T implements Runnable{//方式2 实现Runnable方法 //更加适合在有共享资源的情况下使用
    private int money = 10000;
    @Override
    public void run() {
        while (true){
            synchronized (this){//对象互斥锁，不公平锁，保证一次（同一时间）只能有一个线程执行这个方法
                if(money<1000){
                    System.out.println("余额已经不足了");
                    break;
                }
                money-=1000;
                System.out.println(Thread.currentThread().getName()+"取钱：1000-----剩余money ："+money);
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }
        System.out.println(Thread.currentThread().getName()+"线程已经运行结束~~");
    }
}